//package com.example.myspringboot.mqUnitsTwo;
//
//import com.rabbitmq.client.Channel;
//import org.springframework.amqp.core.Message;
//import org.springframework.amqp.rabbit.annotation.RabbitListener;
//
///**
// * @author zheng
// */
//public class ReceiveHandler {
//
//    //监听email队列
//    @RabbitListener(queues = "inform.email")  //{RabbitmqConfig.QUEUE_INFORM_EMAIL}
//    public void receive_email(Object msg, Message message, Channel channel){
//        System.err.println("QUEUE_INFORM_EMAIL msg"+msg);
//    }
//
//    //监听sms队列
//    @RabbitListener(queues = {RabbitmqConfig.QUEUE_INFORM_SMS})
//    public void receive_sms(Object msg, Message message, Channel channel) {
//        System.err.println("QUEUE_INFORM_SMS msg" + msg);
//    }
//
//}
